//package com.mmy.fta.trade.server.websocket;
//
///**
// * @author qiang.lin
// * @since 2021/11/6
// */
//import java.io.IOException;
//import java.util.HashMap;
//import java.util.Map;
//import java.util.concurrent.ConcurrentHashMap;
//
//import javax.websocket.OnClose;
//import javax.websocket.OnMessage;
//import javax.websocket.OnOpen;
//import javax.websocket.server.PathParam;
//import javax.websocket.server.ServerEndpoint;
//
//import com.alibaba.fastjson.JSON;
//import org.springframework.stereotype.Component;
//
//import javax.websocket.Session;
//
////ws://localhost:8071/websocket/A
//@ServerEndpoint(value = "/websocket/{userId}")
//@Component
//public class WebSocketEndpoint {
//
//    // 与某个客户端的连接会话，需要通过它来给客户端发送数据
//    private Session session;
//
//    /**
//     * 连接建立成功调用的方法
//     */
//    @OnOpen
//    public void onOpen(Session session, @PathParam("userId") String userId) {
//        // 把会话存入到连接池中
//        SessionPool.sessions.put(userId, session);
//    }
//
//    /**
//     * 关闭连接
//     */
//    @OnClose
//    public void onClose(Session session) throws IOException {
//        SessionPool.close(session.getId());
//        session.close();
//    }
//
//    /**
//     * 收到客户端消息后调用的方法
//     *
//     * @param message
//     *            客户端发送过来的消息
//     */
//    @OnMessage
//    public void onMessage(String message, Session session) {
//        SessionPool.sendMessage(message);
//        Map<String,Object> params = JSON.parseObject(message,new HashMap<String,Object>().getClass());
//    }
//
//}
